package com.ai.cltcore.service.common;

import com.ai.frame.bean.InputObject;
import com.ai.cltcore.util.DedicException;
import com.alibaba.rocketmq.client.exception.MQBrokerException;
import com.alibaba.rocketmq.client.exception.MQClientException;
import com.alibaba.rocketmq.remoting.exception.RemotingException;
/**
 * 异步消息服务类
 */
public interface IQueueService {
	/**
	 * 将内容放入消息队列
	 * @param topic 主题
	 * @param key 业务标记
	 * @param inputObject 内容对象
	 * @return
	 * @throws DedicException
	 */
	public boolean sendMsg2MQ(String topic, String key, InputObject inputObject) throws DedicException, MQClientException, RemotingException, MQBrokerException, InterruptedException ;
}
